package demo.components.kafka;

public interface KafkaMessageHandler {
	public void processMessage(KafkaConsumer consumer, String msg, long messageOffset);
}
